package com.example.javabasic.thread.classtwo.future.demo2;

public class Test {
    public static void main(String[] args) throws InterruptedException {
        final RequestQueue queue = new RequestQueue();
        new ClientThread(queue,"哈哈").start();
        ServerThread serverThread = new ServerThread(queue);
        serverThread.start();
        Thread.sleep(3000);
        serverThread.close();
    }
}
